Unix Domain Socket এর Server এবং Client উদাহরণ

নিচে Unix Domain Socket ব্যবহার করে একটি সার্ভার এবং ক্লায়েন্ট প্রোগ্রাম উদাহরণ দেওয়া হলো, যা প্রক্রিয়াগুলোর মধ্যে লোকালি (একই সিস্টেমে) যোগাযোগ করতে সহায়ক। এই উদাহরণে C ভাষা ব্যবহার করা হয়েছে, এবং এটি একটি Stream Socket (SOCK_STREAM) প্রোটোকল ব্যবহার করে TCP-এর মতো ধারাবাহিক (reliable) সংযোগ তৈরি করবে।

Unix Domain Socket Server Program (C ভাষায়)

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/un.h>

#define SOCKET_PATH "/tmp/uds_socket"

int main() {
    int server_fd, client_fd;
    struct sockaddr_un server_addr, client_addr;
    socklen_t client_len;
    char buffer[100];
    
    // 1. Socket তৈরি করা
    if ((server_fd = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) {
        perror("Socket creation failed");
        exit(EXIT_FAILURE);
    }
    
    // 2. ঠিকানা সেটআপ করা
    memset(&server_addr, 0, sizeof(server_addr));
    server_addr.sun_family = AF_UNIX;
    strncpy(server_addr.sun_path, SOCKET_PATH, sizeof(server_addr.sun_path) - 1);

    // 3. Binding করা
    unlink(SOCKET_PATH); // যদি আগে থেকে কোনো ফাইল থাকে, তা মুছে ফেলা
    if (bind(server_fd, (struct sockaddr*)&server_addr, sizeof(server_addr)) < 0) {
        perror("Bind failed");
        close(server_fd);
        exit(EXIT_FAILURE);
    }
    
    // 4. Listening করা
    if (listen(server_fd, 5) < 0) {
        perror("Listen failed");
        close(server_fd);
        exit(EXIT_FAILURE);
    }

    printf("Server is listening...\n");

    client_len = sizeof(client_addr);
    // 5. Accepting সংযোগ
    if ((client_fd = accept(server_fd, (struct sockaddr*)&client_addr, &client_len)) < 0) {
        perror("Accept failed");
        close(server_fd);
        exit(EXIT_FAILURE);
    }

    // 6. ডেটা গ্রহণ করা
    int n = read(client_fd, buffer, sizeof(buffer));
    buffer[n] = '\0';
    printf("Client: %s\n", buffer);

    // 7. ডেটা পাঠানো
    write(client_fd, "Hello from server", 17);

    // 8. Socket বন্ধ করা
    close(client_fd);
    close(server_fd);
    unlink(SOCKET_PATH); // Socket ফাইল মুছে ফেলা

    return 0;
}

Unix Domain Socket Client Program (C ভাষায়)

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/un.h>

#define SOCKET_PATH "/tmp/uds_socket"

int main() {
    int client_fd;
    struct sockaddr_un server_addr;
    char buffer[100];

    // 1. Socket তৈরি করা
    if ((client_fd = socket(AF_UNIX, SOCK_STREAM, 0)) < 0) {
        perror("Socket creation failed");
        exit(EXIT_FAILURE);
    }

    // 2. সার্ভার ঠিকানা সেটআপ করা
    memset(&server_addr, 0, sizeof(server_addr));
    server_addr.sun_family = AF_UNIX;
    strncpy(server_addr.sun_path, SOCKET_PATH, sizeof(server_addr.sun_path) - 1);

    // 3. সার্ভারের সাথে সংযোগ স্থাপন করা
    if (connect(client_fd, (struct sockaddr*)&server_addr, sizeof(server_addr)) < 0) {
        perror("Connection failed");
        close(client_fd);
        exit(EXIT_FAILURE);
    }

    // 4. ডেটা পাঠানো
    char *message = "Hello from client";
    write(client_fd, message, strlen(message));

    // 5. ডেটা গ্রহণ করা
    int n = read(client_fd, buffer, sizeof(buffer));
    buffer[n] = '\0';
    printf("Server: %s\n", buffer);

    // 6. Socket বন্ধ করা
    close(client_fd);

    return 0;
}

প্রোগ্রামের বিশ্লেষণ

Server Program:

1. Socket তৈরি: socket() ফাংশন ব্যবহার করে AF_UNIX এবং SOCK_STREAM দিয়ে একটি Unix Domain Socket তৈরি করা হয়।
2. Binding: bind() ফাংশন ব্যবহার করে Socket-কে একটি নির্দিষ্ট পাথ (/tmp/uds_socket) এ সংযুক্ত করা হয়।
3. Listening: listen() ফাংশন ইনকামিং সংযোগের জন্য সার্ভারকে অপেক্ষা করায়।
4. Accepting: accept() ফাংশন ব্যবহার করে একটি ইনকামিং সংযোগ গ্রহণ করা হয়।
5. ডেটা গ্রহণ: read() ফাংশন ক্লায়েন্ট থেকে ডেটা গ্রহণ করে।
6. ডেটা পাঠানো: write() ফাংশন ব্যবহার করে সার্ভার ক্লায়েন্টে ডেটা পাঠায়।
7. Socket বন্ধ করা: প্রোগ্রাম শেষে সিস্টেমের রিসোর্স মুক্ত করতে close() এবং unlink() ফাংশন ব্যবহার করে Socket বন্ধ এবং মুছে ফেলা হয়।

Client Program:

1. Socket তৈরি: socket() ফাংশন AF_UNIX এবং SOCK_STREAM দিয়ে ক্লায়েন্টের জন্য একটি Socket তৈরি করে।
2. সার্ভারের ঠিকানা সেটআপ: সার্ভারের ঠিকানা (পাথ) server_addr.sun_path-এ সেট করা হয়।
3. Connection: connect() ফাংশন সার্ভারের সাথে সংযোগ স্থাপন করে।
4. ডেটা পাঠানো: write() ফাংশন ব্যবহার করে ক্লায়েন্ট একটি বার্তা পাঠায়।
5. ডেটা গ্রহণ: read() ফাংশন ব্যবহার করে সার্ভার থেকে ডেটা গ্রহণ করে।
6. Socket বন্ধ করা: প্রোগ্রাম শেষে close() ফাংশন ব্যবহার করে Socket বন্ধ করা হয়।

কিভাবে প্রোগ্রামগুলো চালাবেন

প্রথমে সার্ভার প্রোগ্রাম চালু করুন:

• সার্ভার প্রোগ্রাম চালু হলে এটি /tmp/uds_socket পাথে একটি Unix Domain Socket তৈরি করে এবং ইনকামিং সংযোগের জন্য অপেক্ষা করবে।

এরপর ক্লায়েন্ট প্রোগ্রাম চালু করুন:

• ক্লায়েন্ট প্রোগ্রাম চালু হলে এটি সেই একই পাথে (যেখানে সার্ভার অপেক্ষমাণ রয়েছে) সংযোগ স্থাপন করবে এবং বার্তা পাঠাবে।

ক্লায়েন্ট এবং সার্ভারের মধ্যে বার্তা আদান-প্রদান:

• ক্লায়েন্ট একটি বার্তা পাঠাবে, এবং সার্ভার সেটি গ্রহণ করে উত্তরে একটি বার্তা পাঠাবে। উভয় প্রোগ্রাম তাদের নিজ নিজ টার্মিনালে বার্তাগুলো প্রদর্শন করবে।